# Copyright (2023) Beijing Volcano Engine Technology Ltd.
# Licensed under the Apache License, Version 2.0 (the "License");
# you may not use this file except in compliance with the License.
# You may obtain a copy of the License at
#     http://www.apache.org/licenses/LICENSE-2.0
# Unless required by applicable law or agreed to in writing, software
# distributed under the License is distributed on an "AS IS" BASIS,
# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
# See the License for the specific language governing permissions and
# limitations under the License.

from dbaccess.clickhouse.clickhouse import ClickHouseDataAccess
from concurrent.futures import ThreadPoolExecutor

THEADAEXECUTOR = None


def init_global_obj():
    global THEADAEXECUTOR
    THEADAEXECUTOR = ThreadPoolExecutor(10)
    # 初始化全局clickhouse_reader
    ClickHouseDataAccess()


def get_global_thread_executor():
    global THEADAEXECUTOR
    if THEADAEXECUTOR is None:
        THEADAEXECUTOR = ThreadPoolExecutor(10)
    return THEADAEXECUTOR
